a1ccce3b5c703e9084b4961a96bb639d05895fda,contrib/extensions/replication/core/src/test/java/org/apache/sling/replication/queue/impl/PriorityPathQueueDistributionStrategyTest.java,PriorityPathQueueDistributionStrategyTest,testPackageAdditionWithSucceedingItemDeliveryOnPriorityPath,#,65
Before Change
when(properties.get("priority.paths")).thenReturn(new String[]{"/content", "/apps"});
when(context.getProperties()).thenReturn(properties);
priorityPathDistributionStrategy.activate(context);
ReplicationQueueItem replicationPackage = mock(ReplicationQueueItem.class);
when(replicationPackage.getPaths()).thenReturn(new String[]{"/content/sample1"});
ReplicationQueueProvider queueProvider = mock(ReplicationQueueProvider.class);
ReplicationQueue queue = mock(ReplicationQueue.class);
when(queueProvider.getQueue("agentName", "/content")).thenReturn(queue);
when(queue.add(replicationPackage)).thenReturn(true);
ReplicationQueueItemState state = mock(ReplicationQueueItemState.class);
when(state.isSuccessful()).thenReturn(true);
when(queue.getStatus(replicationPackage)).thenReturn(state);
ReplicationQueueItemState returnedState = priorityPathDistributionStrategy.add("agentName", replicationPackage, queueProvider);
assertNotNull(returnedState);
assertTrue(returnedState.isSuccessful());
After Change
ReplicationQueueProvider queueProvider = mock(ReplicationQueueProvider.class);
ReplicationQueue queue = mock(ReplicationQueue.class);
when(queueProvider.getQueue("agentName", "/content")).thenReturn(queue);
when(queue.add(any(ReplicationQueueItem.class))).thenReturn(true);
boolean returnedState = priorityPathDistributionStrategy.add("agentName", replicationPackage, queueProvider);
assertTrue(returnedState);